/**  
 * All rights Reserved, Designed By Suixingpay.
 * @author: chenfeifei[chen_ff@suixingpay.com] 
 * @date: 2017年9月20日 下午5:34:56   
 * @Copyright ©2017 Suixingpay. All rights reserved. 
 * 注意：本内容仅限于随行付支付有限公司内部传阅，禁止外泄以及用于其他的商业用途。
 */
package cn.hennancf.qieqie.mq.easy;

/**  
 * TODO
 * @author: chenfeifei[chen_ff@suixingpay.com]
 * @date: 2017年9月20日 下午5:34:56
 * @version: V1.0
 * @review: chenfeifei[chen_ff@suixingpay.com]/2017年9月20日 下午5:34:56
 */
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Send {

    //队列名称  
    private final static String QUEUE_NAME = "testQueue";  

    public static void main(String[] argv) throws java.io.IOException  
    {  
        int a = 1;
        /** 
         * 创建连接连接到MabbitMQ 
         */  
        ConnectionFactory factory = new ConnectionFactory();  
        //设置MabbitMQ所在主机ip或者主机名   
        factory.setHost("127.0.0.1"); 
        //创建一个连接  
        Connection connection = factory.newConnection();  
        //创建一个频道  
        Channel channel = connection.createChannel();  
        //指定一个队列  
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);  
        //发送的消息  
        String message = "来自发送者的消息" + 1 ;  
            //往队列中发出一条消息  
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes());  
//            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());  
//            System.out.println("Sent '" + message + "'");  
            //关闭频道和连接  
            channel.close();  
            connection.close();  
     }  
}
